/*
package com.adingxiong.pm.config;

import org.springframework.amqp.core.Binding;

import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.Queue;
import org.springframework.amqp.core.TopicExchange;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;


*/
/*@Configuration*//*

public class RabbitMQConfig {
    */
/**
     * 队列名
     *//*

    final static String message = "q_topic_message";
    final static String message1 = "q_topic_message1";

//    @Bean
//    public Queue queue() {
//        return new Queue("q_hello");
//    }


    */
/**
     * 创建队列
     *//*

    @Bean
    public Queue queueMessage (){
        return new Queue(RabbitMQConfig.message);
    }
    @Bean
    public Queue queueMessage1(){
        return  new Queue(RabbitMQConfig.message1);
    }

    */
/**
     * 声明一个交换机
     * @return
     *//*

    @Bean
    TopicExchange exchange(){
        return new TopicExchange("topic-exchange");
    }

    */
/**
     *   绑定队列交换机  并且制定 路由key
     * @param queueMessage
     * @param exchange
     * @return
     *//*

    @Bean
    Binding bindingExchange1(Queue queueMessage,TopicExchange exchange){
        return BindingBuilder.bind(queueMessage).to(exchange).with("topic.message");
    }

    @Bean
    Binding bindingExchange2(Queue queueMessage1,TopicExchange exchange){
        return BindingBuilder.bind(queueMessage1).to(exchange).with("topic.#");
    }
}
*/
